﻿using Amib.Threading;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using YiNing.Tools;

namespace QtingCapturer.Tools
{
    public class ThreadHelper
    {
        static SmartThreadPool smartThreadPool;

        public static SmartThreadPool Instance()
        {
            if (smartThreadPool == null)
            {
                STPStartInfo stp = new STPStartInfo();//线程详细配置参数
                stp.AsReadOnly();//返回一个只读类型的STPStartInfo
                                 //一个枚举值,储存工作项执行完成后是否调用回调方法,
                                 //Never不调用,
                                 //WhenWorkItemCanceled只有当工作项目被取消时调用
                                 //WhenWorkItemNotCanceled只有当工作项目不取消调用
                                 //Always调用
                stp.CallToPostExecute = CallToPostExecute.Always;//在这里选择总是回调
                stp.DisposeOfStateObjects = true;//当工作项执行完成后,是否释放工作项的参数,如果释放,参数对象必须实现IDisposable接口
                stp.IdleTimeout = INIHelper.ReadInteger("SmartThreadPool", "IdleTimeout", 300);// 当线程池中没有工作项时,闲置的线程等待时间,超过这个时间后,会释放掉这个闲置的线程,默认为60秒
                stp.MaxWorkerThreads = INIHelper.ReadInteger("SmartThreadPool", "MaxWorkerThreads", 25);//最大线程数,默认为25,由于windows的机制,所以一般最大线程最大设置成25,如果设置成0的话,那么线程池将停止运行
                                          //只在STP执行Action<...>与Func<...>两种任务时有效
                                          //在执行工作项的过程中,是否把参数传递到WorkItem中去,用做IWorkItemResult接口取State时使用,
                                          //如果设置为false那么IWorkItemResult.State是取不到值的
                                          //如果设置为true可以取到传入参数的数组
                stp.FillStateWithArgs = true;
                //最小线程数,默认为0,当没有工作项时,线程池最多剩余的线程数
                stp.MinWorkerThreads = INIHelper.ReadInteger("SmartThreadPool", "MinWorkerThreads", 25);//5 thread
                                          //当工作项执行完毕后,默认的回调方法
                                          //stp.PostExecuteWorkItemCallback = delegate (IWorkItemResult wir) { MessageBox.Show("ok" + wir.Result); };
                                          //是否需要等待start方法后再执行工作项,?默认为true,当true状态时,STP必须执行Start方法,才会为线程分配工作项
                stp.StartSuspended = false;
                smartThreadPool = new SmartThreadPool(stp);//带线程初始化的线程池初始化

                for (int i = 0; i < stp.MinWorkerThreads; i++)
                {
                    smartThreadPool.QueueWorkItem(() => { Console.WriteLine("yining: Start ThreadHelper " + i); });
                }
            }
            return smartThreadPool;
        }
    }
}
